/***
 *   @title qz
 *   @description <description class purpose>
 *   @author yichen
 *   @version 1.0.0
 *   @create 2023/10/24 0024
 **/
package io.gitee.wokaixin.yunque.message.example;

import io.gitee.wokaixin.yunque.driver.*;
import lombok.*;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.*;

@Component
@Data
public class KafkaConfigI extends KafkaConfig {
    //    kafka配置
//    @Value("${message.kafka.nodeName}")
//    private String nodeName;
    @Value("${message.kafka.topic}")
    private String topic;
    @Value("${message.kafka.brokerList}")
    private String  brokerList;
    @Value("${message.kafka.produceInterval}")
    private int produceInterval;
    @Value("${message.kafka.metadataRefreshIntervalMs}")
    private int metadataRefreshIntervalMs;
    @Value("${message.kafka.isAsyn}")
    private boolean isAsyn;
    @Value("${message.kafka.brokerVersion}")
    private String brokerVersion;
    @Value("${message.kafka.requiredAck}")
    private int requiredAck;
}
